package com.zytech.zspider.eventbus;

/**
 * @author siuming
 */
public interface EventBus {

    /**
     * @param qname
     * @param eventEnvelope
     */
    void postQueue(String qname, EventEnvelope eventEnvelope);

    /**
     * @param tname
     * @param eventEnvelope
     */
    void postTopic(String tname, EventEnvelope eventEnvelope);

    /**
     * @param qname
     * @param listener
     */
    void consumeQueue(String qname, EventListener listener);

    /**
     * @param tname
     * @param listener
     */
    void consumeTopic(String tname, EventListener listener);
}
